package corn

import (
	"github.com/robfig/cron/v3"
	"proxy_resource_test/corn/tasks"
	"proxy_resource_test/utils/logging"
)

func newWithSeconds() *cron.Cron {
	secondParser := cron.NewParser(cron.Second | cron.Minute |
		cron.Hour | cron.Dom | cron.Month | cron.DowOptional | cron.Descriptor)
	return cron.New(cron.WithParser(secondParser), cron.WithChain())
}

func Init() {
	go func() {
		tasks.AcquireSN() // 初始化拉取SN
		crontab := newWithSeconds()
		//if _, err := crontab.AddFunc("0 */1 * * * ?", tasks.DoRsp); err != nil {
		//	log.Print("定时任务:  数据库配置刷新失败：" + err.Error())
		//}
		//if _, err := crontab.AddFunc("*/30  * * * * ?", tasks.StartScheduler); err != nil {
		//	log.Print("定时任务:  拉取数据：" + err.Error())
		//}
		crontab.Start()
		logging.Info("定时任务启动成功")
	}()
}
